package com.liuyu.common.framework.rocketmq.properties;

import lombok.Data;

/**
 * 主题订阅关系
 * @author: liuyu
 * @date: 2022/6/11 21:38
 * @version: 1
 */
@Data
public class TopicSubscribe {
    /**
     * 主题
     */
    private String topicName;
    /**
     * 标签 *则代表监听topic所有,tagName=tag1||tag2||tags3则代表监听部分
     */
    private String tagName;

    //        # 消费者订阅的主题topic和tags,tagName=*则代表监听topic所有,tagName=tag1||tag2||tags3则代表监听部分
//        # 实际业务处理类必须实现MqConsumerInterface接口
//        # 每个topic对应一个处理类,根据topicName获取对应类,例如:mqConsumerHandle.ChenkeTopic,mqConsumerHandle固定值
}
